package com.favccxx.message.domain.message.entity.endpoint;

import lombok.Data;
import lombok.EqualsAndHashCode;
import lombok.ToString;

@Data
@ToString(callSuper = true)
@EqualsAndHashCode(callSuper = true)
public class KafkaEndPoint extends MessageEndPoint {

    private String topic;

    private String brokers;

    private String groupId;

    private boolean autoCommitEnable;

    private int autoCommitIntervalMs;

    private String keyDeserializer;

    private String valueDeserializer;


}
